package org.poem.enums;

public class KafkaEnums {

    /**
     * 数据传输预定的topic
     */
    public static final String DATA_TRANSFORM_TOP = "data_transform_topic";

    /**
     * 全量数据的topic
     */
    public static final String DATA_FULL_TRANSFORM_TO_PRODUCER_TOPIC = "data_full_transform_producer_topic";
    /**
     * 全量数据的topic
     */
    public static final String DATA_FULL_TRANSFORM_TO_PRODUCER_TOPIC_MYSQL = "data_full_transform_producer_topic_mysql";
    /**
     * 全量数据的topic
     */
    public static final String DATA_FULL_TRANSFORM_TO_PRODUCER_TOPIC_POSTGRES = "data_full_transform_producer_topic_postgres";
    /**
     * 全量数据的topic
     */
    public static final String DATA_FULL_TRANSFORM_TO_PRODUCER_TOPIC_SQLSERVER = "data_full_transform_producer_topic_sqlserver";
    /**
     * 曾量数据的topic
     */
    public static final String DATA_INCREMENT_TRANSFORM_PRODUCER_TOPIC = "data_increment_transform_producer_topic";

    /**
     * 数据任务上传
     */
    public static final String TASK_STATUS_CHANGE_TOPIC = "task_status_change_topic";

    /**
     * 数据任务上传
     */
    public static final String DATA_TRANSFORM_TOP_KEY = "data_transform_top_key";
}
